// const mysql = require("mysql2/promise");

// export async function connectToDatabase() {
//   try {
//     // 创建连接配置
//     const connectionConfig = {
//       host: "localhost",
//       user: "root",
//       password: "notebook44",
//       database: "monoly",

//       // 如果你的MySQL服务器配置了SSL，并且你想要使用它，可以添加以下选项：
//       // ssl: {
//       //   rejectUnauthorized: false, // 对于自签名证书，设置为false
//       //   ca: fs.readFileSync('path/to/ca.pem') // 可选，指向CA证书的路径
//       // }
//     };

//     // 连接到MySQL数据库
//     const connection = await mysql.createConnection(connectionConfig);

//     console.log("成功连接到数据库");

//     // 执行查询
//     const [rows, fields] = await connection.execute("SELECT * FROM user");

//     // 处理查询结果
//     console.log(rows);

//     // 关闭连接（注意：在实际应用中，你可能不会在这里立即关闭连接）
//     // await connection.end();
//   } catch (error) {
//     console.error("数据库连接或查询失败:", error);
//   }
// }
// 加载Express模块
const express = require("express");
// 加载CORS模块
// const cors = require("cors");
// 加载MySQL模块
const mysql = require("mysql2/promise");
// const md5 = require("md5");
// 创建MySQL连接池
const pool = mysql.createPool({
  // 数据库服务器的地址
  host: "127.0.0.1",
  // 数据库服务器的端口号
  port: 3306,
  // 数据库用户的用户名
  user: "root",
  // 数据库用户的密码
  password: "notebook44",
  // 数据库名称
  database: "monoly",
  // 编码方式
  charset: "utf8",
  // 最大连接数
  connectionLimit: 20,
});
// 创建WEB服务器实例
const server = express();
// 将CORS作为Server的中间件//解决跨域问题
// server.use(cors({
//   origin:['http://localhost:8080','http://127.0.0.1:8080']
// }))
// 引入body中间件
const bodyParser = require("body-parser");
const { send } = require("process");
// 应用中间件
server.use(
  bodyParser.urlencoded({
    extended: true,
    limit: "100000kb",
  })
);
server.use(
  bodyParser.json({
    limit: "100000kb",
  })
);
//添加产品的接口
server.post("/addproduct", (req, res) => {
  let params = req.body;
  let sql = "SELECT * FROM cake WHERE cname = ?&spec = ?";
  pool.query(sql, [params.cname, params.spec], (err, result) => {
    if (err) throw err;
    if (!result.length) {
      sql =
        "INSERT INTO cake(cname, price, isonsell, launch_time, ctext, spec) values(?,?,?,?,?,?)";
      pool.query(
        sql,
        [
          params.cname,
          params.price,
          params.isonsell,
          params.launch,
          params.text,
          params.spec,
        ],
        (err, result) => {
          if (err) throw err;
        }
      );
      res.send({ code: 1 });
    } else {
      res.send({ code: 0 });
    }
  });
});
//产品详情的接口
server.get("/details", (req, res) => {
  // let sql = "SELECT pic FROM cake_pic WHERE cake_id = ?";
  let sql = "SELECT * FROM user";
  console.log("111");

  pool.query(sql, req, (err, result) => {
    console.log(result);
    if (err) throw err;
    res.send(result);
  });
});

server.listen(8888);
